11d2fd34281aa8a7365c46f033a65eab29898042,hoodie-common/src/test/java/com/uber/hoodie/common/table/log/avro/AvroLogAppenderTest.java,AvroLogAppenderTest,testCompositeAvroLogReader,#,270

Before Change


        logAppender.close();

        logConfig = HoodieLogAppendConfig.newBuilder().onPartitionPath(partitionPath)
            .withLogFileExtension(HoodieLogFile.DELTA_EXTENSION).withFileId("test-fileid1")
            .withSchema(SchemaTestUtil.getSimpleSchema()).withSizeThreshold(500).withFs(fs).build();
        List<HoodieLogFile> allLogFiles = FSUtils
            .getAllLogFiles(fs, partitionPath, logConfig.getLogFile().getFileId(),
                HoodieLogFile.DELTA_EXTENSION).collect(Collectors.toList());

After Change


        logAppender.close();

        logConfig = HoodieLogAppendConfig.newBuilder().onPartitionPath(partitionPath)
            .withLogFileExtension(HoodieLogFile.DELTA_EXTENSION).withFileId("test-fileid1")
            .withBaseCommitTime("100")
            .withSchema(SchemaTestUtil.getSimpleSchema()).withSizeThreshold(500).withFs(fs).build();
        List<HoodieLogFile> allLogFiles = FSUtils
            .getAllLogFiles(fs, partitionPath, logConfig.getLogFile().getFileId(),
                HoodieLogFile.DELTA_EXTENSION, logConfig.getLogFile().getBaseCommitTime())